/******************************************************************************
* Copyright (C) 2020 ShenZhen Powerdata Information Technology Co.,Ltd
* All Rights Reserved.
* 本软件为***研制。未经本公司正式书面同意，其他任何个人、团体不得使用、
* 复制、修改或发布本软件.
*****************************************************************************/

package com.xxl.job.listener.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
* @Title: rocketmq 初始化链接
* @ClassName:  RocketMqConfig   
* @Description:TODO  
* @author: xgf
* @date:   2020年2月23日 上午11:16:14   
* @since   JDK1.8
* @history 2020年2月23日 TODO 新建
*/
@Component
@ConfigurationProperties(prefix = "xxl.job.listener")
@Order(99)
//@PropertySource("classpath:config.properties")
public class RocketMqConfig {
	
	/**
     * Name Server 地址，因为是集群部署 所以有多个用 分号 隔开
     */
    private String namesrv = "172.16.11.12w:9876";
    /**
     * 主题名称 主题一般是服务器设置好 而不能在代码里去新建topic（ 如果没有创建好，生产者往该主题发送消息 会报找不到topic错误）
     */
    private String topic = "job-listener";
    
    /**
     * 生产者组
     */
    private String consumerName = "job_listener_producer";
    /**
     * 邮件名称
     */
    private String subject;
    
    /**
     * 谁发的邮件
     */
    private String from;
    /**
     * 邮件发给谁
     */
    private String to;
    
    
    

    
    
    public String getFrom() {
		return from;
	}
	public void setFrom(String from) {
		this.from = from;
	}
	public String getSubject() {
		return subject;
	}
	public void setSubject(String subject) {
		this.subject = subject;
	}
	public String getTo() {
		return to;
	}
	public void setTo(String to) {
		this.to = to;
	}
	public String getNamesrv() {
		return namesrv;
	}
	public String getConsumerName() {
		return consumerName;
	}
	public void setConsumerName(String consumerName) {
		this.consumerName = consumerName;
	}
	public void setNamesrv(String namesrv) {
		this.namesrv = namesrv;
	}
	public String getTopic() {
		return topic;
	}
	public void setTopic(String topic) {
		this.topic = topic;
	}
    
    
    
    
    
	

}
